package com.ds.common.rocketmq.config;

import com.ds.common.rocketmq.producer.MqProducer;
import org.springframework.boot.autoconfigure.AutoConfiguration;
import org.springframework.context.annotation.Bean;

/**
 * @class: RocketMqConfig
 * @description:
 * @author: fs
 * @create: 2024/6/26 11:50
 **/
@AutoConfiguration
public class RocketMqConfiguration {

    @Bean
    public MqProducer streamProducer() {
        return new MqProducer();
    }
}
